2dd73d171068d743befcd445a14751032d232e4e,src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java,CassandraStorage,getNextWide,#,130

Before Change


                        lastRow = (SortedMap<ByteBuffer,IColumn>)reader.getCurrentValue();
                        return tuple;
                    }
                    tuple = addKeyToTuple(tuple, lastKey, cfDef, parseType(cfDef.getKey_validation_class()));
                }
                SortedMap<ByteBuffer,IColumn> row = (SortedMap<ByteBuffer,IColumn>)reader.getCurrentValue();
                if (lastRow != null) // prepend what was read last time

After Change


                    if (tuple == null)
                        tuple = keyToTuple(key, cfDef, parseType(cfDef.getKey_validation_class()));
                    else
                        addKeyToTuple(tuple, lastKey, cfDef, parseType(cfDef.getKey_validation_class()));
                }
                SortedMap<ByteBuffer,IColumn> row = (SortedMap<ByteBuffer,IColumn>)reader.getCurrentValue();
                if (lastRow != null) // prepend what was read last time